package com.chb.storm.gpstrident;

import java.util.List;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import storm.trident.operation.TridentCollector;
import storm.trident.state.BaseStateUpdater;
import storm.trident.tuple.TridentTuple;

public class GpsHbaseUpdater extends BaseStateUpdater<GpsHbaseState> {

	/**
	 * 
	 */
	private static final long serialVersionUID = -4677771635910372983L;
	private static final Logger LOG = LoggerFactory.getLogger(GpsHbaseUpdater.class);
	
	@Override
	public void updateState(GpsHbaseState state, List<TridentTuple> tuples, TridentCollector collector) {
		LOG.debug("------GpsHbaseUpdater---------updateState-------start");
		state.saveGps(tuples, collector);
		LOG.debug("------GpsHbaseUpdater---------updateState-------end");
	}
	
}
